type net/http/internal/http2.clientStream
32 uses
net/http/internal/http2 (current package)
api.go#L57: stream clientStream
transport.go#L160: streams map[uint32]*clientStream // client-initiated
transport.go#L228: type clientStream struct {
transport.go#L283: func (cs *clientStream) get1xxTraceFunc() func(int, textproto.MIMEHeader) error {
transport.go#L290: func (cs *clientStream) abortStream(err error) {
transport.go#L296: func (cs *clientStream) abortStreamLocked(err error) {
transport.go#L311: func (cs *clientStream) abortRequestBodyWrite() {
transport.go#L321: func (cs *clientStream) closeReqBodyLocked() {
transport.go#L625: streams: make(map[uint32]*clientStream),
transport.go#L1128: func (cc *ClientConn) roundTrip(req *ClientRequest, streamf func(*clientStream)) (*ClientResponse, error) {
transport.go#L1130: req.stream = clientStream{
transport.go#L1187: cancelRequest := func(cs *clientStream, err error) error {
transport.go#L1240: func (cs *clientStream) doRequest(req *ClientRequest, streamf func(*clientStream)) {
transport.go#L1254: func (cs *clientStream) writeRequest(req *ClientRequest, streamf func(*clientStream)) (err error) {
transport.go#L1398: func (cs *clientStream) encodeAndWriteHeaders(req *ClientRequest) error {
transport.go#L1458: func (cs *clientStream) cleanupWriteRequest(err error) {
transport.go#L1565: func (cc *ClientConn) awaitOpenSlotForStreamLocked(cs *clientStream) error {
transport.go#L1633: func (cs *clientStream) frameScratchBufferLen(maxFrameSize int) int {
transport.go#L1671: func (cs *clientStream) writeRequestBody(req *ClientRequest) (err error) {
transport.go#L1807: func (cs *clientStream) awaitFlowControl(maxBytes int) (taken int32, err error) {
transport.go#L1893: func (cc *ClientConn) addStreamLocked(cs *clientStream) {
transport.go#L2198: func (rl *clientConnReadLoop) handleResponse(cs *clientStream, f *MetaHeadersFrame) (*ClientResponse, error) {
transport.go#L2359: func (rl *clientConnReadLoop) processTrailers(cs *clientStream, f *MetaHeadersFrame) error {
transport.go#L2398: cs *clientStream
transport.go#L2609: func (rl *clientConnReadLoop) endStream(cs *clientStream) {
transport.go#L2625: func (rl *clientConnReadLoop) endStreamError(cs *clientStream, err error) {
transport.go#L2630: func (rl *clientConnReadLoop) endStreamErrorLocked(cs *clientStream, err error) {
transport.go#L2643: func (rl *clientConnReadLoop) streamByID(id uint32, headerOrData bool) *clientStream {
transport.go#L2649: func (rl *clientConnReadLoop) streamByIDLocked(id uint32, headerOrData bool) *clientStream {
transport.go#L2663: func (cs *clientStream) copyTrailers() {